package com.learn.kafka.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

import java.util.List;

/**
 * 多写配置类（注入目标 Topic 列表）
 * @author: learn.kafka
 */
@Configuration
@ConfigurationProperties(prefix = "spring.kafka.multi-write")
public class KafkaConfigProperties {

    private List<String> topics;  // 对应配置文件中的 topics 列表


    // getter/setter
    public List<String> getTopics() {
        return topics;
    }
    public void setTopics(List<String> topics) {
        this.topics = topics;
    }
}
